google.golang.org/grpc.ccBalancerWrapper.cc (field)
20 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L65: cc *ClientConn
balancer_wrapper.go#L87: cc: cc,
balancer_wrapper.go#L105: return ccb.cc.metricsRecorderList
balancer_wrapper.go#L121: channelz.Infof(logger, ccb.cc.channelz, "Channel switches to new LB policy %q", name)
balancer_wrapper.go#L159: channelz.Info(logger, ccb.cc.channelz, "ccBalancerWrapper: closing")
balancer_wrapper.go#L181: ccb.cc.mu.Lock()
balancer_wrapper.go#L182: defer ccb.cc.mu.Unlock()
balancer_wrapper.go#L194: ac, err := ccb.cc.newAddrConnLocked(addrs, opts)
balancer_wrapper.go#L196: channelz.Warningf(logger, ccb.cc.channelz, "acBalancerWrapper: NewSubConn: failed to newAddrConn: %v", err)
balancer_wrapper.go#L224: ccb.cc.mu.Lock()
balancer_wrapper.go#L225: defer ccb.cc.mu.Unlock()
balancer_wrapper.go#L226: if ccb.cc.conns == nil {
balancer_wrapper.go#L246: ccb.cc.pickerWrapper.updatePicker(s.Picker)
balancer_wrapper.go#L247: ccb.cc.csMgr.updateState(s.ConnectivityState)
balancer_wrapper.go#L251: ccb.cc.mu.RLock()
balancer_wrapper.go#L252: defer ccb.cc.mu.RUnlock()
balancer_wrapper.go#L260: ccb.cc.resolveNowLocked(o)
balancer_wrapper.go#L264: return ccb.cc.target
balancer_wrapper.go#L355: acbw.ccb.cc.removeAddrConn(acbw.ac, errConnDrain)
balancer_wrapper.go#L446: if acbw.ccb.cc.dopts.disableHealthCheck {